const cloud = require('wx-server-sdk')
// 强制指定环境（替换为您的实际环境ID）
cloud.init({    env: "dzc-aapp-0g1mx02g41e97626", }) // 使用当前云环境

exports.main = async (event, context) => {
  // 调试：打印传入参数
  console.log('event:', JSON.stringify(event, null, 2))
  
  const db = cloud.database()
  const wxContext = cloud.getWXContext()

  // 防御性编程：检查集合是否存在
  const collectionName = 'activities'
  try {
    // 尝试获取集合信息（验证是否存在）
    await db.collection(collectionName).count()
  } catch (err) {
    console.error('集合不存在或无权访问:', err)
    return { errCode: 404, errMsg: '数据库集合不存在' }
  }

  // 数据插入（添加额外调试信息）
  try {
    const res = await db.collection(collectionName).add({
      data: {
        title: String(event.title || ''),
        time: String(event.time || ''),
        description: String(event.description || ''),
        creator: String(event.creator || wxContext.OPENID),
        creatorAvatar: String(event.creatorAvatar || ''),
        participants: [],
        createTime: db.serverDate(),
        _openid: wxContext.OPENID,
        _env: cloud.DYNAMIC_CURRENT_ENV // 记录当前环境
      }
    })
    console.log('插入成功:', res)
    return { success: true, activityId: res._id }
  } catch (err) {
    console.error('数据库写入失败:', err)
    return { 
      errCode: 500, 
      errMsg: '数据库操作失败',
      detail: err.message 
    }
  }
}